package com.yc.web.clients;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import reactor.core.publisher.Flux;

@FeignClient(name = "ai-provider")
public interface AiAgentClient {
    @GetMapping(value = "/api/deepseekchat", produces = MediaType.TEXT_PLAIN_VALUE)  // 改为TEXT_PLAIN
    public Flux<String> chatStream(
            @RequestParam("memoryId") String memoryId,
            @RequestParam("question") String question);
}
